package arithmetic.functionTest.myStream;

import java.util.Iterator;

/**
 * 流终止操作接口(简化版)
 * 只有串行的
 * @author jiangfeng 2020/4/26 17:31
 */
public interface MyTerminalOp<E_IN, R> {
    /**
     * 执行串行终止操作
     */
    <P_IN> R evaluateSequential(MyPipelinHelper<E_IN> helper,
            Iterator<P_IN> iterator);
}
